bed36fff4ff92353d20582596f0eb7dcb4d79391,src/org/jgroups/protocols/pbcast/FLUSH.java,FLUSH,onStartFlush,#Address#FlushHeader#,654
Before Change
flushMembers.removeAll(suspected);
}
Message msg = new Message(null, localAddress, null);
msg.putHeader(getName(), new FlushHeader(FlushHeader.FLUSH_OK, fh.viewID));
down_prot.down(new Event(Event.MSG, msg));
if (log.isDebugEnabled())
log.debug("Received START_FLUSH at " + localAddress + " responded with FLUSH_OK");
}
After Change
flushMembers.removeAll(suspected);
amIParticipant = flushMembers.contains(localAddress);
}
if (amIParticipant)
{
Message msg = new Message(null);
msg.putHeader(getName(), new FlushHeader(FlushHeader.FLUSH_OK, fh.viewID));
down_prot.down(new Event(Event.MSG, msg));
if (log.isDebugEnabled())
log.debug("Received START_FLUSH at " + localAddress + " responded with FLUSH_OK");
}